if (realtime.channels.isNotEmpty) {
      if (realtime.connState == SocketStates.disconnecting) {
        bool cancel = false;
        final connectFuture = realtime.conn!.sink.done.then(

Future<void> disconnect({int? code, String? reason}) async {
    final conn = this.conn;
    if (conn != null) {
      final oldState = connState;
      connState = SocketStates.disconnecting;
      
      
      if (oldState == SocketStates.open ||
          oldState == SocketStates.connecting) {
        if (code != null) {
          await conn.sink.close(code, reason ?? '');
        } else {
          await conn.sink.close();
        }
        connState = SocketStates.disconnected;
        reconnectTimer.reset();
        
      }
      this.conn = null;

      if (heartbeatTimer != null) heartbeatTimer?.cancel();
    }
  }